Sub-sections
Contents
- ProcessSetting
- DefaultMailboxSize = -1
- UnlimitedMaibox = int.MaxValue
- StandardDirectives = { Strategy.With<ProcessKillException>(Directive.Stop), Strategy.With<ProcessSetupException>(Directive.Stop) }
- BlockingQueue <T>
- Capacity
- IsPaused
- IsCancelled
- BlockingQueue (int capacity = 100000)
- ReceiveAsync <S> (S state, Func<S, T, InboxDirective> handler)
- Receive (Func<T, InboxDirective> handler, string name = "")
- Count
- Post (T value)
- Cancel ()
- Pause ()
- UnPause ()
- Dispose ()
- ShutdownCancellationToken
- NodeOffline
- NodeOnline
- PausableBlockingQueue <A>
- IsPaused
- IsCancelled
- PausableBlockingQueue (int boundedCapacity)
- Count
- ReceiveAsync <S> (S state, Func<S, A, InboxDirective> handler)
- Post (A value)
- Cancel ()
- Pause ()
- UnPause ()
- Dispose ()
- Req
- Resp
- ProcessMetaData
- MsgTypeNames
- StateTypeName
- StateTypeInterfaces
- ProcessMetaData (string[] msgTypeNames, string stateTypeName, string[] stateTypeInterfaces)
- GetStateType ()
- ProxyMsg
- Method
- Args
- ArgTypes
- ReturnType
- VoidInvoke (ProcessId pid, string method, params object[] args)
- VoidInvoke0 (ProcessId pid, string method)
- VoidInvoke1 (ProcessId pid, string method, object arg1)
- VoidInvoke2 (ProcessId pid, string method, object arg1, object arg2)
- VoidInvoke3 (ProcessId pid, string method, object arg1, object arg2, object arg3)
- VoidInvoke4 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4)
- VoidInvoke5 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5)
- VoidInvoke6 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6)
- VoidInvoke7 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7)
- VoidInvoke8 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8)
- VoidInvoke9 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9)
- VoidInvoke10 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10)
- VoidInvoke11 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11)
- VoidInvoke12 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11, object arg12)
- Invoke (ProcessId pid, string method, Type rettyp, params object[] args)
- Invoke0 (ProcessId pid, string method, Type rettyp)
- Invoke1 (ProcessId pid, string method, Type rettyp, object arg1)
- Invoke2 (ProcessId pid, string method, Type rettyp, object arg1, object arg2)
- Invoke3 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3)
- Invoke4 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4)
- Invoke5 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5)
- Invoke6 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6)
- Invoke7 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7)
- Invoke8 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8)
- Invoke9 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9)
- Invoke10 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10)
- Invoke11 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11)
- Invoke12 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11, object arg12)
- Reg
- MsgTag
- RelayMsg
- To
- Sender
- ConnectionId
- IsAsk
- Tag
- RelayMsg (MsgTag tag, ClientConnectionId connectionId, ProcessId to, ProcessId sender, bool isAsk)
- InboundRelayMsg
- Message
- InboundRelayMsg (ClientConnectionId connectionId, object msg, ProcessId to, ProcessId sender, bool isAsk)
- OutboundRelayMsg
- Message
- OutboundRelayMsg (ClientConnectionId connectionId, RemoteMessageDTO msg, ProcessId to, ProcessId sender, bool isAsk)
- Return <T>
- IReturn
- Return
- NoReturn
- Msg
- AddToSchedule (string inboxKey, string id, RemoteMessageDTO message)
- Reschedule (string inboxKey, string id, DateTime when)
- RemoveFromSchedule (string inboxKey, string id)
- Check = new CheckMsg()
- AddToScheduleMsg
- RemoveFromScheduleMsg
- RescheduleMsg
- CheckMsg
- State
- Empty = new State(None)
- Scheduled
- State (Option<HashMap<string, HashMap<string, RemoteMessageDTO>>> scheduled)
- Add (string key, string innerKey, RemoteMessageDTO msg)
- Delete (string key, string innerKey)
- TypeHelper
- HasStateTypeOf (Type stateType, Type[] stateTypeInterfaces)
- HasStateTypeOf (Type stateType, string[] stateTypeInterfaces)
- IsMessageValidForProcess (Type messageType, Type[] inboxDeclaredType)
- IsMessageValidForProcess (object message, Type[] inboxDeclaredType)
- IsMessageValidForProcess (object message, string[] inboxDeclaredType)
Sub sections
| Wrappers |
class ProcessSetting Source #
Fields
field int DefaultMailboxSize = -1 Source #
field int UnlimitedMaibox = int.MaxValue Source #
field State<Exception, Option<Directive>>[] StandardDirectives = { Strategy.With<ProcessKillException>(Directive.Stop), Strategy.With<ProcessSetupException>(Directive.Stop) } Source #
class BlockingQueue <T> Source #
Properties
property bool IsCancelled Source #
Constructors
constructor BlockingQueue (int capacity = 100000) Source #
Methods
method IDisposable ReceiveAsync <S> (S state, Func<S, T, InboxDirective> handler) Source #
class ShutdownCancellationToken Source #
Provides the name of a system that is shutting down, use Cancel to stop the shutdown from completing.
class PausableBlockingQueue <A> Source #
Properties
property bool IsCancelled Source #
Constructors
constructor PausableBlockingQueue (int boundedCapacity) Source #
class ProcessMetaData Source #
Fields
field string[] MsgTypeNames Source #
field string StateTypeName Source #
field string[] StateTypeInterfaces Source #
Constructors
constructor ProcessMetaData (string[] msgTypeNames, string stateTypeName, string[] stateTypeInterfaces) Source #
Methods
method Type GetStateType () Source #
Fields
field string ReturnType Source #
Methods
method void VoidInvoke (ProcessId pid, string method, params object[] args) Source #
method void VoidInvoke0 (ProcessId pid, string method) Source #
method void VoidInvoke1 (ProcessId pid, string method, object arg1) Source #
method void VoidInvoke2 (ProcessId pid, string method, object arg1, object arg2) Source #
method void VoidInvoke3 (ProcessId pid, string method, object arg1, object arg2, object arg3) Source #
method void VoidInvoke4 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4) Source #
method void VoidInvoke5 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5) Source #
method void VoidInvoke6 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6) Source #
method void VoidInvoke7 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7) Source #
method void VoidInvoke8 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8) Source #
method void VoidInvoke9 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9) Source #
method void VoidInvoke10 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10) Source #
method void VoidInvoke11 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11) Source #
method void VoidInvoke12 (ProcessId pid, string method, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10, object arg11, object arg12) Source #
method object Invoke2 (ProcessId pid, string method, Type rettyp, object arg1, object arg2) Source #
method object Invoke3 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3) Source #
method object Invoke4 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4) Source #
method object Invoke5 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5) Source #
method object Invoke6 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6) Source #
method object Invoke7 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7) Source #
method object Invoke8 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8) Source #
method object Invoke9 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9) Source #
method object Invoke10 (ProcessId pid, string method, Type rettyp, object arg1, object arg2, object arg3, object arg4, object arg5, object arg6, object arg7, object arg8, object arg9, object arg10) Source #
Fields
field string ConnectionId Source #
class InboundRelayMsg Source #
Constructors
constructor InboundRelayMsg (ClientConnectionId connectionId, object msg, ProcessId to, ProcessId sender, bool isAsk) Source #
class OutboundRelayMsg Source #
Constructors
constructor OutboundRelayMsg (ClientConnectionId connectionId, RemoteMessageDTO msg, ProcessId to, ProcessId sender, bool isAsk) Source #
Fields
field NoReturn Default = new NoReturn() Source #
Fields
field Msg Check = new CheckMsg() Source #
Methods
method Msg AddToSchedule (string inboxKey, string id, RemoteMessageDTO message) Source #
method Msg Reschedule (string inboxKey, string id, DateTime when) Source #
method Msg RemoveFromSchedule (string inboxKey, string id) Source #
class AddToScheduleMsg Source #
Fields
Constructors
constructor AddToScheduleMsg (string inboxKey, string id, RemoteMessageDTO message) Source #
class RemoveFromScheduleMsg Source #
Constructors
constructor RemoveFromScheduleMsg (string inboxKey, string id) Source #
class RescheduleMsg Source #
Constructors
constructor RescheduleMsg (string inboxKey, string id, DateTime when) Source #
class TypeHelper Source #
Methods
method Either<string, bool> HasStateTypeOf (Type stateType, Type[] stateTypeInterfaces) Source #
method Either<string, bool> HasStateTypeOf (Type stateType, string[] stateTypeInterfaces) Source #
method Either<string, bool> IsMessageValidForProcess (Type messageType, Type[] inboxDeclaredType) Source #
method Either<string, object> IsMessageValidForProcess (object message, Type[] inboxDeclaredType) Source #
method Either<string, object> IsMessageValidForProcess (object message, string[] inboxDeclaredType) Source #